c965c5946911063352804e591955e8d1927aed6e,src/test/java/com/continuuity/data/operation/ttqueue/TestHBaseNewTTQueue.java,TestHBaseNewTTQueue,testSingleStatefulConsumerWithHashPartitioning,#,106

Before Change



    // enqueue some entries
    for(int i=0; i<numQueueEntries; i++) {
      QueueEntry queueEntry=new QueueEntryImpl(Bytes.toBytes("value"+i%numConsumers));
      queueEntry.addPartitioningKey(HASH_KEY, i);
      assertTrue(queue.enqueue(queueEntry, dirtyVersion).isSuccess());
    }
    // dequeue it with HASH partitioner

After Change


    // enqueue some more entries
    for(int i=numQueueEntries; i<numQueueEntries*2; i++) {
      QueueEntry queueEntry=new QueueEntryImpl(Bytes.toBytes(i+1));
      queueEntry.addPartitioningKey(HASH_KEY, i+1);
      assertTrue(queue.enqueue(queueEntry, dirtyVersion).isSuccess());
    }
    // dequeue and verify